package org.zhadoop.stream.api.opereators.serdes;

import org.zhadoop.stream.api.ConfigAnnotation;
import org.zhadoop.stream.api.StreamSerDeAnnoation;
import org.zhadoop.streaming.config.StreamingConfig;
import org.zhadoop.streaming.serde.CSVSerDe;

/**
 * 一个简单的，根据分隔符来确定文件序列化和反序列化的API 
 * 
 * 数据的序列化和反序列可以使用一样的参数
 * @author zwd
 *
 */
@StreamSerDeAnnoation(CSVSerDe.class)
public class CSVSerDeAPI extends SerDeAPI{

	@ConfigAnnotation(StreamingConfig.STREAMING_OPERATOR_TIMEZONE)
	private String timezoneForTimestamp;

	public String getTimezoneForTimestamp() {
		return timezoneForTimestamp;
	}

	public void setTimezoneForTimestamp(String timezoneForTimestamp) {
		this.timezoneForTimestamp = timezoneForTimestamp;
	}
}
